package org.hyl.javaext.disruptor;

import com.lmax.disruptor.WorkHandler;

public class DisruptorConsumer  implements WorkHandler<FileData> {
    private static final String FINIDHED = "EOF";
    private int index=0;
    public DisruptorConsumer(int i) {
    	this.index=i;
    }
    @Override
    public void onEvent(FileData event) throws Exception {
       String line = event.getLine();
       // ����
       System.out.println("s"+this.index+":"+line);
        if (line.equals(FINIDHED)) {
            return;
        }
     
    }
}